/*
package com.sprucetec.livechat.consumer.process;

import com.alibaba.dubbo.common.utils.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.sprucetec.livechat.common.NettyMessageDto;
import com.sprucetec.livechat.service.impl.ChatServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

*/
/**
 * @ClassName MessageConsumerProcess
 * @Description:
 * @Author Kenny
 * @Date 2020/4/10
 **//*


@Component("messageConsumerProcess")
public class MessageConsumerProcess {

    @Autowired
    private ChatServiceImpl chatService;

    */
/**
     * 发送组消息
     *
     * @param jsonObject
     *//*

    public void processChatMessage(String jsonObject) {
        NettyMessageDto messageDto = JSONObject.parseObject(JSON.parse(jsonObject).toString(), NettyMessageDto.class);
        chatService.groupSendByMq(messageDto);
    }

    */
/**
     * 关闭连接
     *
     * @param jsonObject
     *//*

    public void processChannelClose(String jsonObject) {
        NettyMessageDto messageDto = JSONObject.parseObject(JSON.parse(jsonObject).toString(), NettyMessageDto.class);
        chatService.removeByMq(messageDto);
    }

}
*/
